package cn.tang.tframe.mq;

import cn.tang.tframe.mq.consumer.IQtMsgProcessor;
import cn.tang.tframe.mq.producer.IQtProducer;

import java.util.Properties;

/**
 * Created by tanghc on 17/2/4.
 */
public interface IQtMqFactory {
	IQtProducer builderPruduer();
	Runnable builderConsumer(String rawTopic,IQtMsgProcessor msgProcessor);
	Runnable builderConsumer(String projectCode,String appCode,String topic,IQtMsgProcessor msgProcessor);
	Runnable builderConsumer(String rawTopic,Properties properties,IQtMsgProcessor msgProcessor);
	Runnable builderConsumer(String projectCode,String appCode,String topic,Properties properties,IQtMsgProcessor msgProcessor);
}
